package org.groupg.project.Indicator;

import com.lmax.disruptor.EventHandler;

public class IndicatorEventHandler implements EventHandler<IndicatorEvent> {
    @Override
    public void onEvent(IndicatorEvent event, long sequence, boolean endOfBatch) {
        // 这里是你的消费者逻辑 - 处理指标并插入数据库
        processIndicator(event.getIndicatorName(), event.getIndicatorData());

        // 如果是批量末尾，可以执行批量提交等优化操作
        if (endOfBatch) {
            // 例如: 批量提交数据库事务
        }
    }

    private void processIndicator(String name, Object data) {
        // 具体的指标处理逻辑
        System.out.println("Processing indicator: " + name);
        // 数据库插入等操作...
    }
}
